package car_test;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.*;
import java.net.URI;

public class hdfs {

    public static void main(String[] args) {
        try {
            // 配置 Hadoop 环境
            Configuration conf = new Configuration();
            conf.set("fs.defaultFS", "hdfs://192.168.128.130/:8020"); // HDFS 地址，请根据实际情况修改

            // 创建 FileSystem 对象
            FileSystem fs = FileSystem.get(URI.create("hdfs://192.168.128.130/:8020"), conf,"root");

            // 本地文件路径
            Path localFilePath = new Path("D:/cxdownload/data.xlsx"); // 替换为你的本地文件路径

            // HDFS 目标路径
            Path hdfsFilePath = new Path("/car/data.csv"); // 替换为你想上传到的 HDFS 路径

            // 上传文件
            fs.copyFromLocalFile(localFilePath, hdfsFilePath);

            System.out.println("文件上传成功！");

            // 关闭 FileSystem
            fs.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
